SQLAlchemy তে SQL Query Execute করার জন্য আপনি Engine বা Connection অবজেক্ট ব্যবহার করতে পারেন। SQLAlchemy Core এবং ORM উভয়ের জন্য SQL স্টেটমেন্ট (যেমন INSERT, SELECT, UPDATE, DELETE) পরিচালনা করার সুবিধা দেয়। এখানে Core পদ্ধতি ব্যবহার করে SQL কিউরি এক্সিকিউট করার উদাহরণ দেখানো হলো।
INSERT Query Execute করা
INSERT কিউরি ব্যবহার করে ডেটাবেসে নতুন ডেটা ইনসার্ট করা হয়। SQLAlchemy তে insert() ফাংশন ব্যবহার করে এটি করা যায়।
উদাহরণ (INSERT):
from sqlalchemy import create_engine, Table, Column, Integer, String, MetaData
# ডেটাবেস ইঞ্জিন তৈরি
engine = create_engine('sqlite:///example.db', echo=True)
# Metadata অবজেক্ট তৈরি
metadata = MetaData()
# টেবিল তৈরি
users = Table('users', metadata,
Column('id', Integer, primary_key=True),
Column('name', String),
Column('age', Integer))
# টেবিল ডেটাবেসে তৈরি করা
metadata.create_all(engine)
# Connection তৈরি এবং INSERT অপারেশন
with engine.connect() as connection:
# INSERT কিউরি চালানো
insert_query = users.insert().values(name="John Doe", age=25)
connection.execute(insert_query)
এখানে insert().values() ব্যবহার করে টেবিল users-এ নতুন রেকর্ড ইনসার্ট করা হচ্ছে।
SELECT Query Execute করা
SELECT কিউরি ব্যবহার করে ডেটাবেস থেকে ডেটা রিড করা হয়। SQLAlchemy তে select() ফাংশন ব্যবহার করে এটি করা যায়।
উদাহরণ (SELECT):
from sqlalchemy import create_engine, Table, Column, Integer, String, MetaData
# ডেটাবেস ইঞ্জিন তৈরি
engine = create_engine('sqlite:///example.db', echo=True)
# Metadata অবজেক্ট তৈরি
metadata = MetaData()
# টেবিল তৈরি
users = Table('users', metadata,
Column('id', Integer, primary_key=True),
Column('name', String),
Column('age', Integer))
# Connection তৈরি এবং SELECT অপারেশন
with engine.connect() as connection:
# SELECT কিউরি চালানো
select_query = users.select()
result = connection.execute(select_query)
# ফলাফল প্রিন্ট করা
for row in result:
print(row)
এখানে, select() ফাংশন ব্যবহার করে সমস্ত users টেবিলের ডেটা রিড করা হচ্ছে। ফলাফলটি একটি লিস্ট হিসেবে ফিরে আসে, এবং প্রতি রেকর্ড একটি tuple হিসেবে প্রদর্শিত হয়।
UPDATE Query Execute করা
UPDATE কিউরি ব্যবহার করে ডেটাবেসে বিদ্যমান ডেটা আপডেট করা হয়। SQLAlchemy তে update() ফাংশন ব্যবহার করে এটি করা যায়।
উদাহরণ (UPDATE):
from sqlalchemy import create_engine, Table, Column, Integer, String, MetaData
# ডেটাবেস ইঞ্জিন তৈরি
engine = create_engine('sqlite:///example.db', echo=True)
# Metadata অবজেক্ট তৈরি
metadata = MetaData()
# টেবিল তৈরি
users = Table('users', metadata,
Column('id', Integer, primary_key=True),
Column('name', String),
Column('age', Integer))
# Connection তৈরি এবং UPDATE অপারেশন
with engine.connect() as connection:
# UPDATE কিউরি চালানো
update_query = users.update().where(users.c.id == 1).values(age=30)
connection.execute(update_query)
এখানে, update().where() ব্যবহার করে id 1 এর রেকর্ডের age কলাম আপডেট করা হচ্ছে।
DELETE Query Execute করা
DELETE কিউরি ব্যবহার করে ডেটাবেস থেকে রেকর্ড মুছে ফেলা হয়। SQLAlchemy তে delete() ফাংশন ব্যবহার করে এটি করা যায়।
উদাহরণ (DELETE):
from sqlalchemy import create_engine, Table, Column, Integer, String, MetaData
# ডেটাবেস ইঞ্জিন তৈরি
engine = create_engine('sqlite:///example.db', echo=True)
# Metadata অবজেক্ট তৈরি
metadata = MetaData()
# টেবিল তৈরি
users = Table('users', metadata,
Column('id', Integer, primary_key=True),
Column('name', String),
Column('age', Integer))
# Connection তৈরি এবং DELETE অপারেশন
with engine.connect() as connection:
# DELETE কিউরি চালানো
delete_query = users.delete().where(users.c.id == 1)
connection.execute(delete_query)
এখানে, delete().where() ব্যবহার করে id 1 এর রেকর্ডটি ডেটাবেস থেকে মুছে ফেলা হচ্ছে।
Session ব্যবহারের মাধ্যমে SQL Query Execute করা
SQLAlchemy তে Session ব্যবহারের মাধ্যমে SQL স্টেটমেন্ট চালানো সম্ভব। নিচে একটি উদাহরণ দেওয়া হলো যেখানে INSERT এবং SELECT কিউরি Session এর মাধ্যমে চালানো হয়েছে।
উদাহরণ:
from sqlalchemy import create_engine, MetaData, Table, Column, Integer, String
from sqlalchemy.orm import sessionmaker
# ডেটাবেস ইঞ্জিন তৈরি
engine = create_engine('sqlite:///example.db', echo=True)
# Metadata অবজেক্ট তৈরি
metadata = MetaData()
# টেবিল তৈরি
users = Table('users', metadata,
Column('id', Integer, primary_key=True),
Column('name', String),
Column('age', Integer))
# টেবিল ডেটাবেসে তৈরি করা
metadata.create_all(engine)
# Session তৈরি
Session = sessionmaker(bind=engine)
session = Session()
# INSERT Query চালানো
new_user = users.insert().values(name="Jane Doe", age=28)
session.execute(new_user)
session.commit()
# SELECT Query চালানো
select_query = users.select()
result = session.execute(select_query)
# ফলাফল প্রিন্ট করা
for row in result:
print(row)
# Session বন্ধ করা
session.close()
এখানে Session ব্যবহার করে INSERT এবং SELECT কিউরি কার্যকর করা হয়েছে। session.execute() এর মাধ্যমে SQLAlchemy কিউরি চালানো হয় এবং session.commit() এর মাধ্যমে ইনসার্ট করা ডেটা ডেটাবেসে সেভ হয়।
সারাংশ
SQLAlchemy তে SQL কিউরি যেমন INSERT, SELECT, UPDATE, এবং DELETE চালানো খুবই সহজ এবং কার্যকরী। Core পদ্ধতিতে insert(), select(), update(), এবং delete() ফাংশন ব্যবহার করে ডেটাবেস অপারেশনগুলো সম্পাদন করা হয়। এছাড়া Session ব্যবহারের মাধ্যমে SQLAlchemy ORM দিয়ে ডেটাবেসে অপারেশন করা যায়। SQLAlchemy ডেটাবেসের সাথে যোগাযোগ ও কার্যক্রম পরিচালনা করার জন্য একটি শক্তিশালী এবং নমনীয় টুল সরবরাহ করে।
Read more
